package com.ht.api.task.ad;

import java.util.List;

import javax.sql.DataSource;

import com.ht.api.db.DbConfig;
import com.ht.api.db.Entity;
import com.ht.api.db.task.DataToCacheTask;
import com.ht.api.service.SopService;

import cn.hutool.json.JSONObject;
import lombok.extern.slf4j.Slf4j;

/**
 * 创建旅程用户广告任务
 * @author asq
 * @createTime 2025年3月7日 12:52:03
 */
@Slf4j
public class CreateSopUserAdTask extends DataToCacheTask{

	@Override
	public String getName() {
		return "创建旅程用户广告任务";
	}

	@Override
	protected List<Entity> getDbList(JSONObject param, String groupId, long taskId) {
		// 获取数据源
		long tenantId = param.getLong("tenant_id");
		DataSource ds = DbConfig.useTenantDb(tenantId);

		log.info("num " + param.getInt("num"));

		// 获取参数
		Entity planUser = param.getBean("planUser", Entity.class);

		List<Entity> taskList = SopService.planAdToUser(tenantId, ds, planUser);

        return taskList;
	}
}
